package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    //将消息推送给对应的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws IOException, MqException, ClassNotFoundException;
}

